package top.roadvast.pdshopping.config;

import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.FanoutExchange;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @Author 郭泽鹏
 * @Date 2021/12/29 9:17
 * @Version 1.0
 * @Description rabbitmq配置类：用于测试广播模式
 * 获取所有日志信息
 */
@Configuration
public class FanoutLogConfig {
    //创建交换机
    @Bean
    public FanoutExchange getFanoutLogExchange() {
        return new FanoutExchange("pd_log_fanout_exchange", true, false);
    }
}
